package org.apache.flink.runtime.blob;

import org.apache.flink.api.common.ConsumerID;

/**
 * {@link PermanentBlobService} extension that gives access to register and release consumer artifacts.
 */
public interface ConsumerPermanentBlobService extends PermanentBlobService {
    /**
     * Register the given job.
     *
     * @param jobId job id identifying the job to register
     */
    void registerJob(ConsumerID jobId);

    /**
     * Release the given job. This makes the blobs stored for this job up for cleanup.
     *
     * @param jobId job id identifying the job to register
     */
    void releaseJob(ConsumerID jobId);
}
